package com.future.taskdemo.config;

import org.future.task.redis.cluster.AbstractCommand;
import org.future.task.redis.cluster.CEntry;
import redis.clients.jedis.Pipeline;

public class Def extends AbstractCommand {
    @Override
    public void expand(Pipeline pipeline, CEntry cEntry) {
        switch (cEntry.getCtype()) {
            case DEL:
                pipeline.del(cEntry.getBigKey());
                break;
            default:
        }
    }
}
